package com.kloooong.top.push;

import com.alibaba.fastjson.JSONObject;
import com.dingteam.push.api.channel.*;
import com.dingteam.push.api.message.OrgSuiteAuthMessage;
import com.dingteam.push.api.message.OrgSuiteTicketMessage;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.stereotype.Component;

@Component
@EnableBinding(OrgSuiteAuthChannel.class)
public class BizId04 {


    @StreamListener(target = OrgSuiteAuthInput.INPUT ,condition = "headers['syncAction']=='org_suite_auth' and headers['suiteId']=='"+Contain.stuidId666+"'")
    public void suid666(OrgSuiteAuthMessage orgSuiteAuth) {
        System.out.println("666 04 data is coming 。。。");
        System.out.println("data："+ JSONObject.toJSONString(orgSuiteAuth));
    }


    @StreamListener(target = OrgSuiteAuthInput.INPUT ,condition = "headers['syncAction']=='org_suite_auth' and headers['suiteId']=='"+Contain.stuidId777+"'")
    public void suid777(OrgSuiteAuthMessage orgSuiteAuth) {
        System.out.println("777 04 data is coming 。。。");
        System.out.println("data："+ JSONObject.toJSONString(orgSuiteAuth));
    }



}
